package com.sdk.bigdata.client;

import com.sdk.bigdata.model.BaseModel;

import java.util.concurrent.LinkedBlockingQueue;

/**
 * dataProducer与dataConsumer公用队列
 */
class DataQueue {

    /**
     * 公用队列停止使用标记
     */
    static volatile boolean shutdownFlag = false;

    private static class queueSingle {
        static LinkedBlockingQueue<BaseModel> single = new LinkedBlockingQueue<>();
    }

    static LinkedBlockingQueue<BaseModel> getQueue() {
        return queueSingle.single;
    }

}
